package cc.example;

import org.reactivestreams.Subscription;
import reactor.core.publisher.BaseSubscriber;
import reactor.core.publisher.Flux;
import reactor.core.publisher.SignalType;

import java.io.IOException;
import java.time.Duration;

public class FluxSubscribeDemo {
    public static void main(String[] args) throws IOException {

        Flux<String> flux = Flux.range(1, 10)
                .map(integer -> "哈哈 " + integer);

        flux.subscribe();

    }
}
